/**
 * 管理所有的socket连接
 * 
 * @author bian
 * @createDate 2016.9.1
 */
var messageEmitter = require("./event");
var util = require("util");

module.exports = (io) => {
    var sockets = [];
    
    io.on("connection",function(socket){
        console.log("a new connection");
        sockets.push(socket);
        
        socket.on("disconnect",function(){
             sockets.splice(sockets.indexOf(socket),1);     // 删除此socket
        });
    });

    messageEmitter.on("a new message",(data) => {
        if(sockets.length !== 0){
            for(var st of sockets){
                st.emit("message",data);        // 先发出去自己的
                st.broadcast.emit("message",data);        // 再广播出去给其他的
                break;
            }
        }
    });
    
};


